# _*_ encoding:utf-8 _*_

# TODO： 在celery运行之处，首先加载django配置环境
import django
import os
# 执行配置文件导包路径
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'backend.settings.dev')
# 调用django接口函数手动加载配置
django.setup()

from celery import Celery


# 1. 创建异步程序对象
celery_app = Celery('backend')


# 2. 加载配置文件
# 注意：异步程序是在celery_tasks包所在目录做为工作目录运行的
celery_app.config_from_object('celery_tasks.config')

# 3. 注册异步任务：异步任务是以python包的形式封装的
celery_app.autodiscover_tasks([
    'celery_tasks.sms',  # 任务包的导包路径
    'celery_tasks.email',  # email任务包的导包路径
])








